package com.bdqn;

import redis.clients.jedis.Jedis;

/**
 * RedisRunable 多线程
 *
 * @author LILIBO
 * @since 2025/4/1
 */
public class RedisRunnable implements Runnable {

    @Override
    public void run() {
        // 连接 redis 服务器，127.0.0.1:6379
        Jedis jedis = new Jedis("127.0.0.1", 6379);
        // 权限认证，指定密码
        jedis.auth("lilibo");

        // 分布式锁（setnx，只有在key不存在时才能设置，设置成功返回1，否则返回0）
        long lock = jedis.setnx("LOCK", Thread.currentThread().getName());
        System.out.println(Thread.currentThread().getName() + "抢锁" + (lock == 1 ? "成功" : "失败"));
    }

}
